const connection = require('../app/database.js')
// 所有和数据库相关的操作
class commentServer {

  // 发表评论
  async create(content , moment_id , user_id){
    // 1. 获取动态内容 拼接 statement
    const statement = 'INSERT INTO `comment` (content , moment_id , user_id) VALUES (?, ? , ?);'
    // 2. 执行sql语句 异步的操作
    const [result] = await connection.execute(statement, [content,moment_id , user_id])
    return result
  }

  async reply(content , moment_id , user_id , comment_id){
    // 1. 获取动态内容 拼接 statement
    const statement = 'INSERT INTO `comment` (content , moment_id , user_id , comment_id) VALUES (?, ? , ? ,?);'
    // 2. 执行sql语句 异步的操作
    const [result] = await connection.execute(statement, [content,moment_id , user_id,comment_id])
    return result
  }


}
module.exports = new commentServer()